d58701195805ce319002e4f6b9a47d289999a959,products/stratos/modules/integration/test-common/src/main/java/org/apache/stratos/integration/common/TopologyHandler.java,TopologyHandler,assertTopologyInitialized,#,163
Before Change
private void assertTopologyInitialized() {
log.info(String.format("Asserting topology initialization within %d ms", TOPOLOGY_INIT_TIMEOUT));
long startTime = System.currentTimeMillis();
boolean topologyInitialized = TopologyManager.getTopology().isInitialized();
while (!topologyInitialized) {
try {
Thread.sleep(1000);
} catch (InterruptedException ignore) {
}
topologyInitialized = TopologyManager.getTopology().isInitialized();
if ((System.currentTimeMillis() - startTime) > TOPOLOGY_INIT_TIMEOUT) {
break;
}
After Change
private void assertTopologyInitialized() {
log.info(String.format("Asserting topology initialization within %d ms", TOPOLOGY_INIT_TIMEOUT));
long startTime = System.currentTimeMillis();
while (!TopologyManager.getTopology().isInitialized()) {
log.info("Waiting for topology to be initialized...");
sleep(1000);
if ((System.currentTimeMillis() - startTime) > TOPOLOGY_INIT_TIMEOUT) {
break;
}
}
if (TopologyManager.getTopology().isInitialized()) {
log.info(String.format("Topology initialized under %d ms", (System.currentTimeMillis() - startTime)));
}
assertTrue(String.format("Topology didn't get initialized within %d ms", TOPOLOGY_INIT_TIMEOUT),